package com.jingtao.rabbitmq.consumer;

/**
 * @ClassName:
 * @Description:
 * @Author: zengfanzhen
 * @Date: 2024/4/8 21:59:00
 */

import org.springframework.context.annotation.Configuration;

@Configuration
public class QueueDeclaration {

//    @Autowired
//    private AmqpAdmin amqpAdmin;
//
//    @Bean
//    public Queue directQueue() {
//        // 创建一个名为'direct_queue'的队列，并且设置autoDeclare属性为true
//        Queue queue = new Queue("direct_queue", true);
//        amqpAdmin.declareQueue(queue); // 声明队列
//        return queue;
//    }
}


